iT邦幫忙

2021 iThome 鐵人賽

DAY 15
0
Software Development

從零開始Reactive Programming- Spring系列 第 16

[Day 15] Reactive Programming -Reactor(COLD VS HOT) -PART 2

  • 分享至 

  • xImage
  •  

前言

其實有一個特別的例子是just,直覺會認為just就是產生一個publisher等人來subscribe,理所當然就是Cold Publisher,我一開始也是這樣認為,直到看到官方doc說明他是Hot Publisher,原來最熟悉的好朋友其實如此的陌生,又在程式的道路上學習了人生的一課,Cold Publisher是Lazy loading,但其實just在assembly time就已經準備好所有的data,當有Subscriber訂閱只是在replay一次而已。

defer

使用Flux.just的時候,在assembly time就已經取得資料,我們可以改成透過defer,回歸lazy,直到subscribe才會取資料,defer就是延遲的意思,透過Supplier來達到延遲的效果,來源資料會被延遲到subscribe才會被初始化,也是因為這樣,如果來源資料是與當下時間有關,這樣每個不同的subscribe都會取到不同的時間,但本質上還是一個Cold Publisher。
https://ithelp.ithome.com.tw/upload/images/20210929/20141418bTtz2GEQJA.png

以下範例是分別透過just & defer來取用現在時間,可以看出just每次subscribe結果會相同,就能得知just在assembly time就已經取資料了,而defer則是延遲直到subscribe才真的去取得現在時間,看到這邊可以會有點錯亂,原本以為Hot Publisher是每次結果會不相同,但這邊的Hot Publisher是just 每次結果相同,COLD Publisher的defer則會每次不同,老實說我是有點錯亂,官方文件上也沒有明確定義cold & hot,所以我個人認為是產生資料的時間點,如果是lazy的要等到subscribe才會觸發的就是COLD Publisher,如果無論有沒有subscribe都會先取得資料的,則是Hot Publisher。

Mono<Long> clock = Mono.just(System.currentTimeMillis());
Mono<Long> clockDefer = Mono.defer(() -> Mono.just(System.currentTimeMillis()));

Thread.sleep(500);
clock.subscribe(t -> System.out.println("clock:"+ t));
clockDefer.subscribe(t -> System.out.println("\tclockDefer:"+ t));

Thread.sleep(500);
clock.subscribe(t -> System.out.println("clock:"+ t));
clockDefer.subscribe(t -> System.out.println("\tclockDefer:"+ t));
/*
clock:1631980808996 
	clockDefer:1631980809602 
clock:1631980808996 
	clockDefer:1631980810105 */

COLD VS HOT

再比較一次COLD 與HOT的不同,第一個範例是先用fromIterable產生一個cold publisher,兩個Subscriber 得到的結果是一模一樣的。

Flux<String> source =
    Flux.fromIterable(Arrays.asList("blue", "green", "orange", "purple"))
        .map(String::toUpperCase);

source.subscribe(d -> System.out.println("Subscriber 1: " + d));
source.subscribe(d -> System.out.println("Subscriber 2: " + d));
/*
Subscriber 1: BLUE
Subscriber 1: GREEN
Subscriber 1: ORANGE
Subscriber 1: PURPLE
Subscriber 2: BLUE
Subscriber 2: GREEN
Subscriber 2: ORANGE
Subscriber 2: PURPLE 
*/ 

https://ithelp.ithome.com.tw/upload/images/20210929/20141418I3G8q9pIUa.png

再來利用前面學到的Sinks動態的產生Flux,當時就有提到後面subscribe的只會得到之後的資料,可以看到Subscriber 2 就只有橘色與紫色。

Sinks.Many<String> hotSource = Sinks.unsafe().many().multicast().directBestEffort(); 
Flux<String> hotFlux = hotSource.asFlux().map(String::toUpperCase); 
hotFlux.subscribe(d -> System.out.println("Subscriber 1 to Hot Source: "+d)); 
hotSource.emitNext("blue", FAIL_FAST);  
hotSource.tryEmitNext("green").orThrow();  
hotFlux.subscribe(d -> System.out.println("Subscriber 2 to Hot Source: "+d)); 
hotSource.emitNext("orange", FAIL_FAST); 
hotSource.emitNext("purple", FAIL_FAST); 
hotSource.emitComplete(FAIL_FAST);
/*
Subscriber 1 to Hot Source: BLUE 
Subscriber 1 to Hot Source: GREEN 
Subscriber 1 to Hot Source: ORANGE 
Subscriber 2 to Hot Source: ORANGE 
Subscriber 1 to Hot Source: PURPLE 
Subscriber 2 to Hot Source: PURPLE
*/

https://ithelp.ithome.com.tw/upload/images/20210929/20141418SFJPEWncLj.png

結語

經過兩天的學習,應該能大致了解cold/hot publihser,不過其實官方文件並沒有明確定義,所以建議也不用太鑽牛角尖的想去定義每一個operator是屬於哪一種,遇到再來討論。

圖片來源

資料來源


上一篇
[Day 14] Reactive Programming -Reactor(COLD VS HOT) -PART 1
下一篇
[Day 16] Reactive Programming -Reactor(ConnectableFlux)
系列文
從零開始Reactive Programming- Spring32
圖片
  直播研討會
圖片
{{ item.channelVendor }} {{ item.webinarstarted }} |
{{ formatDate(item.duration) }}
直播中

尚未有邦友留言

立即登入留言